8160bf0535049e1e44baee889d981e5c9a1ddccb,rxbinding/src/main/java/com/jakewharton/rxbinding/view/ViewDragOnSubscribe.java,ViewDragOnSubscribe,call,#Subscriber#,23
Before Change
}
};
Subscription subscription = AndroidSubscriptions.unsubscribeOnMainThread(new Action0() {
@Override public void call() {
view.setOnDragListener(null);
}
});
subscriber.add(subscription);
view.setOnDragListener(listener);
}
After Change
this.handled = handled;
}
@Override public void call(final Subscriber<? super DragEvent> subscriber) {
checkUiThread();
View.OnDragListener listener = new View.OnDragListener() {
@Override public boolean onDrag(View v, DragEvent event) {
if (handled.call(event)) {
if (!subscriber.isUnsubscribed()) {
subscriber.onNext(event);
}
return true;
}
return false;
}
};
subscriber.add(new MainThreadSubscription() {
@Override protected void onUnsubscribe() {
view.setOnDragListener(null);
}
});
view.setOnDragListener(listener);
}